//package com.eks.websocket.v1;
//
//import lombok.RequiredArgsConstructor;
//import org.apache.commons.lang3.StringUtils;
//import org.springframework.web.bind.annotation.PostMapping;
//import org.springframework.web.bind.annotation.RequestMapping;
//import org.springframework.web.bind.annotation.RequestParam;
//import org.springframework.web.bind.annotation.RestController;
//import org.springframework.web.socket.TextMessage;
//import org.springframework.web.socket.WebSocketSession;
//
//import java.io.IOException;
//import java.util.Objects;
//
//@RestController
//@RequiredArgsConstructor
//@RequestMapping("/websocket/server")
//public class TestController {
//
//
//    @PostMapping("/send")
//    public String sender(@RequestParam String key, @RequestParam String message) throws IOException {
//        WebSocketSession session;
//        if(StringUtils.isBlank(key)){
//            session = WebSocketSessionManager.get();
//        }else {
//            session = WebSocketSessionManager.get(key);
//        }
//        if(Objects.nonNull(session) && session.isOpen()){
//            synchronized (session) {
//                session.sendMessage(new TextMessage(message));
//            }
//        }
//        return "OK";
//    }
//}
